fa7df52f4add7663cef207819ff05b03745df2b7,kafka-scheduler/src/main/java/org/apache/mesos/kafka/scheduler/KafkaScheduler.java,KafkaScheduler,KafkaScheduler,#KafkaSchedulerConfiguration#Environment#,65
Before Change
stageScheduler = new DefaultStageScheduler(offerAccepter);
repairScheduler = new KafkaRepairScheduler(
configState.getTargetName(),
kafkaState,
offerRequirementProvider,
offerAccepter);
After Change
stageScheduler = new DefaultStageScheduler(offerAccepter);
repairScheduler = new KafkaRepairScheduler(
configState.getTargetName().toString(),
kafkaState,
offerRequirementProvider,
offerAccepter);